package com.galeno.dao;

import com.galeno.pojo.CombineCondition;
import com.galeno.pojo.EventParam;
import com.galeno.pojo.LogBean;
import org.apache.flink.api.java.utils.ParameterTool;

import java.sql.SQLException;
import java.util.List;

/**
 * @author galeno
 * @Title:
 * @Description:
 * @date 2021/11/1319:41
 */
public interface HistoryEventDao {

    default void close() throws Exception{};


    default void init(ParameterTool parameterTool) throws Exception{};

    //不论是从状态查询，还是从ClickHouse中查询，还是从未来要切换的DorisDB中查询
    //都需要传入查询条件（LogBean bean, List<CombineCondition> combineConditions），
    //只要返回符合条件的行为字符串即可
    String queryEventSequenceStr(LogBean bean, CombineCondition combineCondition) throws SQLException, Exception;



}
